package com.tuniu.agents.common.message;

import reactor.core.publisher.Flux;

public interface ConversationManager{

    String saveConversationResponse(String conversationId, String requestId,String responseId, String content);

    String saveConversationFooter(String conversationId, String requestId,String responseId, String content);

    String saveConversationResponse(String conversationId,String content);

    void saveConversationRequest(String conversationId, String requestId, String responseId, String message,Integer isDeleted);

    Flux<String> getQuestions(String conversationId);

    public void streamToDatabase(String conversationId, String requestId, String responseId);

    String checkAntispam(String conversationId, String requestId, String responseId, String content);

}
